package com.ot.flink.cdc.function.sink;

/**
 * todo
 *
 * @author: pangtt
 * @date: 2023/5/9
 * @since JDK1.8 version: 1.0.0
 */
public class SinkFactory {

    public static KafkaSink getInstance() {
        return new KafkaSink();
    }

}
